package com.yege.sink;

import com.yege.table.HTableBase;
import com.yege.table.HTableRow;
import org.apache.flink.api.common.functions.MapFunction;

public class HbaseBaseMap<T extends HTableBase> implements MapFunction<T, HTableRow> {

    @Override
    public HTableRow map(T value) throws Exception {
        return HTableRow.build(value);
    }
}
